//package com.bsj.power.job.task.handle;
//
//import com.bsj.consumerQ.method.QueueAndRun;
//import com.bsj.power.job.config.constant.QueueConstant;
//import com.bsj.power.job.task.RunAllService;
//import com.bsj.power.job.task.handle.impl.DefaultAnomalousJobHandleRun;
//import lombok.extern.slf4j.Slf4j;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.stereotype.Service;
//
///**
// * @author yinhao
// * @version 1.0
// * @description 作业人员检测任务
// * @date 2024/8/7
// */
//@Service("defaultAnomalousJobService")
//@Slf4j
//public class DefaultAnomalousJobService implements RunAllService {
//
//    @Autowired
//    private DefaultAnomalousJobHandleRun defaultAnomalousJobHandleRun;
//
//    private QueueAndRun queueAndRun = null;
//
//    /**
//     * 文件存储路径名称
//     */
//    private static final String NAME = "defaultAnomalousJob";
//
//    @Override
//    public void init() {
//        if (queueAndRun == null) {
//            queueAndRun = new QueueAndRun(QueueConstant.worker, QueueConstant.popCount, QueueConstant.maxWorker);
//            queueAndRun.start(NAME, defaultAnomalousJobHandleRun);
//        }
//    }
//
//    @Override
//    public void stop() {
//        if (queueAndRun != null) {
//            queueAndRun.stop();
//        }
//    }
//
//    @Override
//    public void doRun(Object object) throws Exception {
//
//    }
//
//    @Override
//    public void doPush(byte[] bytes) throws Exception {
//        if (queueAndRun == null) {
//            init();
//        }
//        queueAndRun.push(bytes);
//    }
//}
